b1c60d2b33815d7ba2136b5c3318f7dbae3ee062,tools/stress/src/org/apache/cassandra/stress/operations/CqlCounterAdder.java,CqlCounterAdder,run,#Cassandra.Client#,43
Before Change
try
{
client.execute_cql_query(ByteBuffer.wrap(query.toString().getBytes()), Compression.NONE);
success = true;
}
catch (Exception e)
After Change
if (session.getColumnFamilyType() == ColumnFamilyType.Super)
throw new RuntimeException("Super columns are not implemented for CQL");
if (cqlQuery == null)
{
StringBuilder query = new StringBuilder(
"UPDATE Counter1 USING CONSISTENCY " + session.getConsistencyLevel().toString() + " SET ");
for (int i = 0; i < session.getColumnsPerKey(); i++)
{
if (i > 0)
query.append(",");
query.append('C').append(i).append("=C").append(i).append("+1");
}
query.append(" WHERE KEY=?");
cqlQuery = query.toString();
}
String key = String.format("%0" + session.getTotalKeysLength() + "d", index);
String formattedQuery = null;
long start = System.currentTimeMillis();
boolean success = false;
String exceptionMessage = null;
for (int t = 0; t < session.getRetryTimes(); t++)
{
if (success)
break;
try
{
if (session.usePreparedStatements())
{
Integer stmntId = getPreparedStatement(client, cqlQuery);
client.execute_prepared_cql_query(stmntId,
Collections.singletonList(ByteBufferUtil.bytes(getUnQuotedCqlBlob(key))));
}
else
{
if (formattedQuery == null)
formattedQuery = formatCqlQuery(cqlQuery, Collections.singletonList(getUnQuotedCqlBlob(key)));
client.execute_cql_query(ByteBuffer.wrap(formattedQuery.getBytes()), Compression.NONE);
}
success = true;